package com.ynet.middleground.riskmanage.mq;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;

/**
 * @InterfaceName SinkBlchzt
 * @Description 保理池质押/解除质押状态相关通道
 * @Author zhangyongbin
 * @Date 2020/8/26 15:25
 * @Version 1.0
 */
public interface SinkBlchzt {

    /**
     * 中台接收入池状态消息（核心-->风控）
     */
    String BLXD_TO_JKZTFK_BLCHZT_IN = "blxd_to_jkztfk_blchzt_in";

    /**
     * 中台接收出池状态消息（核心-->风控）
     */
    String BLXD_TO_JKZTFK_BLCHZT_OUT = "blxd_to_jkztfk_blchzt_out";

    /**
     * 核心业务系统主动向金控中台推送入池结果数据
     *
     * @return
     */
    @Input(SinkBlchzt.BLXD_TO_JKZTFK_BLCHZT_IN)
    SubscribableChannel receiveInState();

    /**
     * 核心业务系统主动向金控中台推送出池结果数据
     *
     * @return
     */
    @Input(SinkBlchzt.BLXD_TO_JKZTFK_BLCHZT_OUT)
    SubscribableChannel receiveOutState();

}
